<?php 
namespace app\queue\controller;

use think\Controller;
use think\queue\Job;
use think\Db;

use app\common\model\PayBisOrder;
use customtool\Utils;
use phpmailer\Email;

class Index extends Controller { 
    public function fire(Job $job, $data) {
        $isJobDone = $this->send($data);       
        if ($isJobDone) {
            //成功删除任务
            $job->delete();
        } else {
            //任务轮询4次后删除
            //通过这个方法可以检查这个任务已经重试了几次了
            if ($job->attempts() > 3) {  
                
                // 第1种处理方式：重新发布任务,该任务延迟3600秒后再执行
//                $job->release(10); 
                // 第2种处理方式：原任务的基础上1分钟执行一次并增加尝试次数
                // $job->failed();   
                // 第3种处理方式：删除任务
                 $job->delete();  
            }

        }
    }
    
    public function failed($data) {
        // ...任务达到最大重试次数后，失败了
        Email::send('wowchky@163.com', '测试失败', $data);
    }
    
    /**
     * 根据消息中的数据进行实际的业务处理
     * @param array|mixed    $data     发布任务时自定义的数据
     * @return boolean                 任务执行的结果
     */
    private function send($data) {
        $retData = json_decode($data, true);
        $mchntOrderid = $retData['mchnt_orderid'];  // 商户订单号
        $PayBisOrder = new PayBisOrder();
        $resPayBisOrder = $PayBisOrder->get(['mchnt_orderid' => $mchntOrderid]);
        if($resPayBisOrder) {
            $result = Utils::curlRetStr($resPayBisOrder->pay_callbackurl, $retData);
            Utils::log('queue/index/send', $mchntOrderid, $result);
            if($result == 'SUCCESS') {
                $payBisOrderData['is_notice'] = 1;
                $PayBisOrder->updateById($payBisOrderData, $resPayBisOrder->id);
                return true;
            } else {
                return false;
            }  
        } else {
            return false;
        }         
    }
    
    // 业务
    public function queue() {
        // \think\Queue::push('app\admin\controller\Queue@fire', '284560@qq.com', $queue = '777');
        // \think\Queue::push('app\common\queue\QueueClient@sendMAIL', '28456049@qq.com', $queue = null);
        \think\Queue::push('app\admin\controller\Work@fire', '28456049@qq.com', $queue = '好队列');
                echo 'ok';
    }
}
